9441f715f2d699c372d86c149f203918880ce30d,sql/src/main/java/io/crate/protocols/postgres/SimplePortal.java,SimplePortal,sync,#Planner#StatsTables#,160
Before Change
}
statsTables.logExecutionStart(jobId, query);
StatsTablesUpdateListener statsTablesUpdateListener = new StatsTablesUpdateListener(jobId, statsTables);
resultReceiver.completionFuture().whenComplete(statsTablesUpdateListener);
if (!analysis.analyzedStatement().isWriteOperation()) {
resultReceiver = new ResultReceiverRetryWrapper(
After Change
statsTables.logExecutionStart(jobId, query);
StatsTablesUpdateListener statsTablesUpdateListener = new StatsTablesUpdateListener(jobId, statsTables);
CompletableFuture completableFuture = resultReceiver.completionFuture().whenComplete(statsTablesUpdateListener);
if (!resumeIfSuspended()) {
rowReceiver = new RowReceiverToResultReceiver(resultReceiver, maxRows);
portalContext.getExecutor().execute(plan, rowReceiver, this.rowParams);
}
synced = true;
return completableFuture;
}
@Override